package com.lili.collection.mq.config;

import com.lili.collection.core.config.InputConfig;
import com.lili.collection.core.domain.CollectCommonConfig;
import com.lili.collection.core.plugins.InputPlugin;
import com.lili.collection.mq.plugins.KafkaInputPlugin;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;

import java.util.Properties;

/**
 * 描述: kafka消息队列插件
 *
 * @date:2023/3/17 17:22
 * @author:lili
 */
@Slf4j
@Data
public class KafkaInputConfig extends CollectCommonConfig implements InputConfig {

    /**
     * kafka配置
     */
    private Properties properties;

    /**
     * 组名
     */
    private String groupName;

    /**
     * topic名称
     */
    private String topicName;

    @Override
    public InputPlugin getPlugin() {
        return new KafkaInputPlugin();
    }
}